package com.ztrue.framework.disruptor;

import com.ztrue.framework.infrastructure.IDistribute;

import java.util.function.Consumer;

/**
 * 表示一个用于执行命令的对象
 *
 * @author zhangw
 * @date 2016/11/6 21:54
 * @version: 1.0
 */
public interface IMessageQueue<M extends IDistribute> {
    /**
     * 发送一个消息
     *
     * @param consumer
     */
    void send(Consumer<M> consumer);
}
